package com.qf;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;

/**
 * 管道演示
 */
public class JedisDemo5 {
    public static void main(String[] args) {

        Jedis jedis = JedisPoolUtils.getJedis();

        long start = System.currentTimeMillis();

//        for (int i = 0; i < 1000; i++) {
//            jedis.set("key"+i,"value"+i);
//        }

        //基于jedis管道写出数据
        Pipeline pipelined = jedis.pipelined();

        //管道类似于io流中的缓冲区，将数据打包形式发送到redis服务器，在redis服务器中依然是单线程一个一个执行
        //管道节省的网络传输时间，redis服务器的执行时间并不会有影响。管道是一个客户端技术
        for (int i = 0; i < 1000; i++) {
            pipelined.set("key"+i,"value"+i);
        }

        long end = System.currentTimeMillis();

        System.out.println("耗时：" + (end-start));

        jedis.close();
    }
}
